
public class TestConnect implements Runnable{
	private TestProcessor processor;
	private int count=0;
	public TestConnect(){
		processor=new TestProcessor(this);
		Thread th=new Thread(processor);
		th.start();
	}

	public void run() {
		while(true){
			Task task=new Task(count++);
			processor.assign(task);
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
	
}
